package com.qingyan.flink.core.trans;

import com.qingyan.flink.core.properties.FlinkProperties;
import com.qingyan.flink.core.properties.FlinkTransProperties;
import com.qingyan.flink.core.sink.SinkBuilder;
import com.qingyan.flink.core.source.cdc.CDCBuilder;

import java.util.List;

/**
 * 上游表一致
 *
 * @author csp 2023-12-25
 */
public class UpstreamConsistentOperation extends AbstractOperation {

    public UpstreamConsistentOperation(FlinkProperties properties, FlinkTransProperties transProperties) {
        super(properties, transProperties);
    }

    @Override
    public Operation create(FlinkProperties properties, FlinkTransProperties transProperties) {
        return new UpstreamConsistentOperation(properties, transProperties);
    }

    @Override
    public String valid() {
        return null;
    }
}
